package top.doe.jobmanager;

import top.doe.rpc.RpcGateway;

import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;

public interface JobMasterGateway extends RpcGateway {

    public String registerTaskExecutor(String taskExecutorAddress,String resourceId) throws ExecutionException, InterruptedException;

    public CompletableFuture<String> getMasterId();
}
